using AhpilyServer;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace AhpilyServers
{
    /// <summary>
    /// 创建客户端的连接池
    /// </summary>
    class ClientPeerPool
    {
        private Queue<ClientPeer> clientPeers; 
        public ClientPeerPool(int capacity)
        {
            clientPeers = new Queue<ClientPeer>(capacity);
        }
        public void Enqueue(ClientPeer item)
        {
            clientPeers.Enqueue(item);
        }
        public ClientPeer Dequeue()
        {
            return clientPeers.Dequeue();
        }
    }
}
